package com.fpx.xms.api.rabbitmq.consumer;

import javax.annotation.Resource;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.amqp.rabbit.core.ChannelAwareMessageListener;

import com.fpx.open.platform.service.AEOrderService;
import com.fpx.open.platform.service.InvokeLogService;
import com.fpx.xms.api.rabbitmq.converter.FastJsonMessageConverter;

public abstract class AbstractOrderConsumer implements ChannelAwareMessageListener{
	
	protected final Logger logger = LoggerFactory.getLogger(getClass());
	
	@Resource
	protected AEOrderService AEOrderService;
	
	
	@Resource
	protected InvokeLogService invokeLogService ;
	
	@Resource
	protected FastJsonMessageConverter msgConverter ;
	

	protected boolean hasConsume(String msgId){
		boolean result = AEOrderService.hasConsume(msgId); 
		return result ;
	}

}
